//package com.sky.config;
//
//
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.amqp.rabbit.annotation.Exchange;
//import org.springframework.amqp.rabbit.annotation.Queue;
//import org.springframework.amqp.rabbit.annotation.QueueBinding;
//import org.springframework.amqp.rabbit.annotation.RabbitListener;
//import org.springframework.context.annotation.Configuration;
//
//
//
//@Configuration
//@Slf4j
//public class RabbitMQConfig {
//
//    // 交换机 & 队列名称
//    public static final String DELAYED_EXCHANGE = "order.delayed.exchange";
//    public static final String DELAYED_QUEUE = "order.delayed.queue";
//    public static final String DELAYED_ROUTING_KEY = "order.delayed";
//
//    @RabbitListener(bindings = @QueueBinding(
//            value = @Queue(name = DELAYED_QUEUE, durable = "true"),
//            exchange = @Exchange(name = DELAYED_EXCHANGE, delayed = "true"),
//            key = DELAYED_ROUTING_KEY
//    ))
//    public void listenDelayMessage(String msg){
//        log.info("接收到delay.queue的延迟消息：{}", msg);
//
//    }
//}
